package demo.delay;

import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;


@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface KafkaDelayListener {

    /**
     * 渠道名称
     *
     * @return
     */
    String channelName();

    /**
     * 主题
     *
     * @return
     */
    String topic();

    /**
     * 延迟消费的时间,单位毫秒
     *
     * @return
     */
    int delayTimeSec() default 120;

    /**
     * 消费者pause时间,单位毫秒
     *
     * @return
     */
    int pauseTimeSec() default 2;


    /**
     * 消费重试次数
     *
     * @return
     */
    int retryTimes() default 3;

}
